package com.daykw.xiaohongshu.mq;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

import com.daykw.xiaohongshu.model.TArticleTask;

public class TQueue {
	private static BlockingQueue<TArticleTask> aqueue = new ArrayBlockingQueue<TArticleTask>(10000000);
	private static BlockingQueue<TArticleTask> cqueue = new ArrayBlockingQueue<TArticleTask>(10000000);

	public static synchronized BlockingQueue<TArticleTask> getCQueue() {
		return cqueue;
	}

	public static synchronized BlockingQueue<TArticleTask> getAQueue() {
		return aqueue;
	}

}
